A brief introduction to sparklyr

What to do when code is slow?

mtcars %>% lm(mpg ~ wt + cyl, .)

# Sample
mtcars %>% dplyr::sample_n(10) %>% lm(mpg ~ wt + cyl, .)

# Profile
profvis::profvis(mtcars %>% lm(mpg ~ wt + cyl, .))

# Scale Up
cloudml::cloudml_train("train.R")

# Scale Out
mtcars_tbl %>% sparklyr::ml_linear_regression(mpg ~ wt + cyl)

Attribution: Javier Luraschi’s talk slides from SDSS 2019

Scaling up vs scaling out

source: https://hadoop4usa.wordpress.com/2012/04/13/scale-out-up/

Scaling out

MapReduce (Hadoop) was the original big kid on the block in terms of scaling out.

Reminder of how MapReduce works

source: https://www.edureka.co/blog/mapreduce-tutorial/

Hadoop vs Spark

source: http://www.big-data.tips/apache-spark-vs-hadoop

Hadoop vs Spark

source: https://data-flair.training/blogs/spark-vs-hadoop-mapreduce/

Choice for scaling out

Spark’s increases in speed and ease of use means there is now a faster and smoother kid on the block…

How/where can you use Spark

source: Zaharia et al. (2016). Apache Spark: A Unified Engine For Big Data Processing

source: https://www.slideshare.net/SparkSummit/trends-for-big-data-and-apache-spark-in-2017-by-matei-zaharia

Leading Spark cloud platforms

sparklyr + Databricks demo

Notebook 1 - Install sparklyr on Databricks cluster

Notebook 2 - Analysis demo

Full code from today’s demo

Notebook

Resources:

• spark.rstudio.com:
  Main documentation site with examples and reference functions.
• community.rstudio.com:
  sparklyr questions? Use the the RStudio Community.
• stackoverflow.com/tags/sparklyr:
  General questions? Stack Overflow is a good place to start.
• gitter.im/rstudio/sparklyr:
  Anything urgent? Chat with on the RStudio sparklyr Gitter!
• https://docs.databricks.com/spark/latest/sparkr:
  Databricks Spark + R documentation?

Attribution: Javier Luraschi’s talk slides from SDSS 2019